package com.jch.dm5_producer_consumer.reusable_code.work_stealing;

import com.jch.dm5_producer_consumer.reusable_code.Channel;

import java.util.concurrent.BlockingDeque;

public interface WorkStealingEnabledChannel<P> extends Channel<P> {

    P take(BlockingDeque<P> preferredQueue) throws InterruptedException;
}
